Node / ReticulumProjects / MeshChatX.git / files / meshchatx / src / backend / auto_resend_guard.py

Displaying Raw • Download

T8b949e# SPDX-License-Identifier: 0BSD

T8b949e"""Guards for auto-resending failed LXMF messages without flooding peers."""

Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations

Tff7b72import T7ee787asyncio

Tff7b72import T7ee787hashlib

Tff7b72import T7ee787json

Tff7b72import T7ee787time

Tff7b72from T7ee787typing Tff7b72import Te6edf3Any

T8b949e# Max automatic replacement sends per failed lineage before requiring manual retry.

Te6edf3MAX_AUTO_RESEND_ATTEMPTS Tff7b72= T79c0ff3

T8b949e# Minimum seconds between auto-resend claims for the same failed row.

Te6edf3AUTO_RESEND_COOLDOWN_SECONDS Tff7b72= T79c0ff120

T8b949e# Skip auto-resend when a recent outbound with the same body already exists.

Te6edf3RECENT_SAME_CONTENT_SECONDS Tff7b72= T79c0ff300

Te6edf3AUTO_RESEND_COUNT_FIELD Tff7b72= Ta5d6ff"Ta5d6ff_mcx_auto_resend_countTa5d6ff"

Tff7b72def Td2a8ffcontent_fingerprintTb4b4b4(Te6edf3contentTb4b4b4: Tffa657str Tff7b72| Tff7b72NoneTb4b4b4) Tff7b72-Tff7b72> Tffa657strTb4b4b4:

Te6edf3raw Tff7b72= Tb4b4b4(Te6edf3content Tff7b72or Ta5d6ff"Ta5d6ff"Tb4b4b4)Tff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4, Te6edf3errorsTff7b72=Ta5d6ff"Ta5d6ffreplaceTa5d6ff"Tb4b4b4)

Tff7b72return Te6edf3hashlibTff7b72.Td2a8ffsha256Tb4b4b4(Te6edf3rawTb4b4b4)Tff7b72.Td2a8ffhexdigestTb4b4b4(Tb4b4b4)

Tff7b72def Td2a8ffread_auto_resend_countTb4b4b4(Te6edf3fields_rawTb4b4b4: Te6edf3AnyTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

Te6edf3fields Tff7b72= Te6edf3_parse_fieldsTb4b4b4(Te6edf3fields_rawTb4b4b4)

Tff7b72tryTb4b4b4:

Tff7b72return Tffa657maxTb4b4b4(T79c0ff0Tb4b4b4, Tffa657intTb4b4b4(Te6edf3fieldsTff7b72.Td2a8ffgetTb4b4b4(Te6edf3AUTO_RESEND_COUNT_FIELDTb4b4b4, T79c0ff0Tb4b4b4)Tb4b4b4)Tb4b4b4)

Tff7b72except Tb4b4b4(Tf85149TypeErrorTb4b4b4, Tf85149ValueErrorTb4b4b4)Tb4b4b4:

Tff7b72return T79c0ff0

Tff7b72def Td2a8fffields_with_auto_resend_countTb4b4b4(Te6edf3fields_rawTb4b4b4: Te6edf3AnyTb4b4b4, Te6edf3countTb4b4b4: Tffa657intTb4b4b4) Tff7b72-Tff7b72> Tffa657strTb4b4b4:

Te6edf3fields Tff7b72= Te6edf3_parse_fieldsTb4b4b4(Te6edf3fields_rawTb4b4b4)

Te6edf3fieldsTb4b4b4[Te6edf3AUTO_RESEND_COUNT_FIELDTb4b4b4] Tff7b72= Tffa657maxTb4b4b4(T79c0ff0Tb4b4b4, Tffa657intTb4b4b4(Te6edf3countTb4b4b4)Tb4b4b4)

Tff7b72return Te6edf3jsonTff7b72.Td2a8ffdumpsTb4b4b4(Te6edf3fieldsTb4b4b4)

Tff7b72def Td2a8ff_parse_fieldsTb4b4b4(Te6edf3fields_rawTb4b4b4: Te6edf3AnyTb4b4b4) Tff7b72-Tff7b72> Tffa657dictTb4b4b4:

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3fields_rawTb4b4b4, Tffa657dictTb4b4b4)Tb4b4b4:

Tff7b72return Tffa657dictTb4b4b4(Te6edf3fields_rawTb4b4b4)

Tff7b72if Tff7b72not Te6edf3fields_rawTb4b4b4:

Tff7b72return Tb4b4b4{Tb4b4b4}

Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3fields_rawTb4b4b4, Tffa657strTb4b4b4)Tb4b4b4:

Tff7b72tryTb4b4b4:

Te6edf3parsed Tff7b72= Te6edf3jsonTff7b72.Td2a8ffloadsTb4b4b4(Te6edf3fields_rawTb4b4b4)

Tff7b72except Tb4b4b4(Tf85149TypeErrorTb4b4b4, Tf85149ValueErrorTb4b4b4, Te6edf3jsonTff7b72.Td2a8ffJSONDecodeErrorTb4b4b4)Tb4b4b4:

Tff7b72return Tb4b4b4{Tb4b4b4}

Tff7b72return Te6edf3parsed Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3parsedTb4b4b4, Tffa657dictTb4b4b4) Tff7b72else Tb4b4b4{Tb4b4b4}

Tff7b72return Tb4b4b4{Tb4b4b4}

Tff7b72class T56d364AutoResendCoordinatorTb4b4b4:

T8b949e"""Per destination asyncio lock so announce/ping/path cannot race-resend."""

Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4) Tff7b72-Tff7b72> Tff7b72NoneTb4b4b4:

Tff7b72selfTff7b72.Td2a8ff_locksTb4b4b4: Tffa657dictTb4b4b4[Tffa657strTb4b4b4, Te6edf3asyncioTff7b72.Td2a8ffLockTb4b4b4] Tff7b72= Tb4b4b4{Tb4b4b4}

Tff7b72def Td2a8fflock_forTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3identity_keyTb4b4b4: Tffa657strTb4b4b4, Te6edf3destination_hashTb4b4b4: Tffa657strTb4b4b4) Tff7b72-Tff7b72> Te6edf3asyncioTff7b72.Td2a8ffLockTb4b4b4:

Te6edf3key Tff7b72= Ta5d6fffTa5d6ff"Tffd700{Te6edf3identity_keyTffd700}Ta5d6ff:Tffd700{Te6edf3destination_hashTffd700}Ta5d6ff"

Te6edf3lock Tff7b72= Tff7b72selfTff7b72.Td2a8ff_locksTff7b72.Td2a8ffgetTb4b4b4(Te6edf3keyTb4b4b4)

Tff7b72if Te6edf3lock Tff7b72is Tff7b72NoneTb4b4b4:

Te6edf3lock Tff7b72= Te6edf3asyncioTff7b72.Td2a8ffLockTb4b4b4(Tb4b4b4)

Tff7b72selfTff7b72.Td2a8ff_locksTb4b4b4[Te6edf3keyTb4b4b4] Tff7b72= Te6edf3lock

Tff7b72return Te6edf3lock

Tff7b72def Td2a8ffshould_skip_for_budgetTb4b4b4(

Te6edf3fields_rawTb4b4b4: Te6edf3AnyTb4b4b4, Tff7b72*Tb4b4b4, Te6edf3max_attemptsTb4b4b4: Tffa657int Tff7b72= Te6edf3MAX_AUTO_RESEND_ATTEMPTS

Tb4b4b4) Tff7b72-Tff7b72> Tffa657boolTb4b4b4:

Tff7b72return Te6edf3read_auto_resend_countTb4b4b4(Te6edf3fields_rawTb4b4b4) Tff7b72>Tff7b72= Te6edf3max_attempts

Tff7b72def Td2a8ffnext_attempt_countTb4b4b4(Te6edf3fields_rawTb4b4b4: Te6edf3AnyTb4b4b4) Tff7b72-Tff7b72> Tffa657intTb4b4b4:

Tff7b72return Te6edf3read_auto_resend_countTb4b4b4(Te6edf3fields_rawTb4b4b4) Tff7b72+ T79c0ff1

Tff7b72def Td2a8ffcooldown_untilTb4b4b4(

Te6edf3nowTb4b4b4: Tffa657float Tff7b72| Tff7b72None Tff7b72= Tff7b72NoneTb4b4b4, Tff7b72*Tb4b4b4, Te6edf3secondsTb4b4b4: Tffa657int Tff7b72= Te6edf3AUTO_RESEND_COOLDOWN_SECONDS

Tb4b4b4) Tff7b72-Tff7b72> Tffa657floatTb4b4b4:

Tff7b72return Tffa657floatTb4b4b4(Te6edf3now Tff7b72if Te6edf3now Tff7b72is Tff7b72not Tff7b72None Tff7b72else Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4) Tff7b72+ Tffa657floatTb4b4b4(Te6edf3secondsTb4b4b4)